#pragma once
#include<string>
#include<KafkaBase.h>
#include"KafkaMgrs.h"
class IMiddlewareMgr
{
public:
	virtual ~IMiddlewareMgr() = default;
	virtual void SendToMiddleware(const std::string& sessionId, const std::vector<uint8_t>& data) = 0;
};
class MiddlewareMgr_Kafka : public IMiddlewareMgr
{
public:
	void SendToMiddleware(const std::string& sessionId, const std::vector<uint8_t>& data) override {
		KafkaMgrLS::GetInstance().SendAsync(sessionId, data, nullptr);
	}
};
